package com.flute.haflute.jobbox.base.mapreduce;

import java.util.List;

/**
 * Mapreduce中间结果的保存库基类
 * 
 * @author Liu Liu
 * @date 2010-5-17
 */
public interface OutputCollector {

	/**
	 * map 任务产生的 <Key,Value> 对 
	 * @param key
	 *            map任务产生的Key
	 * @param val
	 *            和上面Key联系的Value.
	 */
	void collect(String key, String val);

	public List<Object> getKeys();
	
	public List<Object> getVals();

}
